package com.xqls.server.netty.future;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * @author lubycoder@163.com
 */
public class SyncWriteMap {
    /**
     * 发送指令
     */
    public static Map<String, WriteFuture> writeRecords = new ConcurrentHashMap<String, WriteFuture>();


    /**
     * 等待结果
     */
    public static Map<String, WriteFuture> waitSamplingResponses = new ConcurrentHashMap<String, WriteFuture>();



    /**
     * 等待结果
     */
    public static Map<String, WriteFuture> waitValueResponses = new ConcurrentHashMap<String, WriteFuture>();
}
